# -*- coding: utf-8 -*-
'''
@author: Hugo
@file: main.py
@time: 2021/11/28 11:15
'''
import os
from celery import Celery

'''
1. 创建celery运行环境
2. 实例化celery对象
3. 设置任务队列
4. 任务检测
5. 启动
'''

os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'tuling_mall.settings')

# 别名 'tuling'
app = Celery('tuling')

app.config_from_object('celery_tasks.config')

# 任务检测
app.autodiscover_tasks(['celery_tasks.sms'])

# cmd 命令行中启动 celery -A celery_tasks.main worker -l INFO
'''
celery 4.0+ 版本不支持windows的进程任务调度 需要使用协程完成
上面的命令适用与 linux&macOS

pip install eventlet
windows 执行命令：celery -A celery_tasks.main worker -l INFO -P eventlet -c 1000  (1000代表线程数)

'''










